package com.baorant.streamreceiver.service;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface IReceiverService {
//    @Input("dpb-exchange")
    @Input("log-exchange")
    SubscribableChannel receiver();
}